package com.ververica.cdc.guass.sink.jdbc.mysql.database.dialect;

import com.ververica.cdc.guass.sink.jdbc.core.database.dialect.AbstractDialectConverter;
import org.apache.flink.annotation.Internal;
import org.apache.flink.table.types.logical.RowType;

/**
 * Runtime converter that responsible to convert between JDBC object and Flink internal object for
 * MySQL.
 */
@Internal
public class MySQLDialectConverter extends AbstractDialectConverter {

    private static final long serialVersionUID = 1L;

    @Override
    public String converterName() {
        return "MySQL";
    }

    public MySQLDialectConverter(RowType rowType) {
        super(rowType);
    }
}
